package cn.zd.demo.flink.statebackend.constant;

public interface ConfigConstant {
    interface KAFKA1 {
        String SERVER = "192.168.58.22:9092";
        String TOPIC = "cust_baseinfo";
        String GROUPID = "g1";
    }

    interface KAFKA2 {
        String SERVER = "192.168.58.22:9092";
        String TOPIC = "cust_extendinfo";
        String GROUPID = "g1";
    }


    interface DB {
        String DRIVERCLASS = "com.mysql.cj.jdbc.Driver";
//        final String URL = "jdbc:mysql://192.168.58.22:3306/kafka2mysql?autoReconnect=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false";
        final String URL = "jdbc:mysql://localhost:3306/kafka2mysql?autoReconnect=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false";
        final String USERNAME = "root";
        final String USERPWD = "root";
//        String URL = "jdbc:mysql://192.168.58.22:2881/kafka2ob?autoReconnect=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false";
//        String USERNAME = "ob";
//        String USERPWD = "ob";
    }
}
